In [1]: import rocksdb

In [2]: db = rocksdb.DB('./test-db', rocksdb.Options(create_if_missing=True, wal_recovery_mode='kPointInTimeRecovery', recycle_log_file_num=2))

In [3]: db.create_column_family('a')
Out[3]: 'a'

In [4]: db.put(b'ok', b'ok', 'a')  # PUT("ok", "ok") in CF a

In [5]: db.put(b'key1', b'wal1')  # PUT("key1", "wal1") in CF default 

In [6]: db.flush('a')  # Flush CF a to trigger a new WAL to be cut. Now there are two unflushed WALs for CF default

In [7]: db.put(b'key2', b'wal2')  # PUT("key2", "wal2") in CF default

In [8]: del db

In [3]: db = rocksdb.DB('./test-db', rocksdb.Options(create_if_missing=True, wal_recovery_mode='kPointInTimeRecovery', recycle_log_file_num=2), column_families=['default', 'a'])

In [4]: db.get(b'key1'). # DB contains nothing for key1

In [5]: db.get(b'key2'). # Meanwhile, it contains the value for "key2", which is supposed to be newer!
Out[5]: b'wal2'